package org.lzfto.flink.demo.business.flinkTest.flinkObjects.watermark;

import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;
import org.lzfto.flink.demo.business.orders.SimpleOrder;

/**
*
*@author lzfto
*@创建时间 2025年7月3日 10:24:21
*/
public class SimpleOrderTimestampAssigner implements SerializableTimestampAssigner<SimpleOrder> {
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	@Override
	public long extractTimestamp(SimpleOrder element, long recordTimestamp) {
		return element.getEventTime().getTime();
	}

}
